package com.tanjor.kafka.producer;

import java.util.Map;

public interface KafkaService {
	
	/**
	 * kafka发送消息模板
	 * @param topic 主题
	 * @param value	messageValue
	 * 不使用分区  
	 */
	public Map<String,Object> sendMsg(String topic, Object value);
	
	/**
	 * kafka发送消息模板
	 * @param topic 主题
	 * @param value	messageValue
	 * @param partitionNum 分区数 如果是否使用分区为0,分区数必须大于0
	 */
	public Map<String,Object> sendMsg(String topic, Object value,Integer partitionNum);

	/**
	 * kafka发送消息模板
	 * @param topic 主题
	 * @param value	messageValue
	 * @param partitionNum 分区数 如果是否使用分区为0,分区数必须大于0
	 * @param role 角色:bbc app erp...
	 */
	public Map<String,Object> sendMsg(String topic, Object value, 
			Integer partitionNum, String role);
}
